package com.activemq.springtest.start;

import org.apache.activemq.broker.BrokerFactory;
import org.apache.activemq.broker.BrokerService;

import java.net.URI;

public class TxBroker1 {
    public static void main(String[] args) throws Exception {
        String uri = "properties:broker.properties";
        BrokerService broker = BrokerFactory.createBroker(new URI(uri));
        broker.addConnector("tcp://127.0.0.1:61616");
        broker.start();
    }
}
